package com.zhengbo.flink.demo.base.constant;

/**
 * @program: mq-flink
 * @description: ${description}
 * @author: maqiang
 * @create: 2019/7/25
 *
 */

public class FlinkConstant {

	public final static String KAFKA_BROKER_LIST = "10.0.10.21:15386,10.0.10.22:15386,10.0.10.23:15386";

	public static final String SOCKET_HOST ="127.0.0.1";

	public static final Integer SOCKET_PORT =18951;

	public static final String WORD_COUNT_FILE_PATH ="D:\\myTestProject\\mq-flink\\flink-test\\src\\main\\resources/word-count-file.txt";
}
